import threading
import time,os
import pandas as pd
from strategy_by_boll_2 import *

if __name__ == '__main__':
    print("********** 主程序开始执行，开始监控相关的交易品种 **********")
    #----------------------------------------------------------------
    #定时发送邮件
    threading.Thread(target=apscheduler_send_mail).start()
    #----------------------------------------------------------------
    #监控Excel表中所有品种
    excelFile ="parameter.xls"
    df = pd.DataFrame(pd.read_excel(excelFile))
    print("监控Excel表中所有品种： ")
    #输出待监控的交易品种
    print(df['Symbol'])
    #循环启动多个监控线程
    #允许开仓次数
    trade_count=100000
    x=0
    while x<df.shape[0]:
        if df.iloc[x][0]!="" and df.iloc[x][1]!="" and df.iloc[x][2]!="":
            threading.Thread(target=order_by_boll,args=(df.iloc[x][0],int(df.iloc[x][1]),int(df.iloc[x][2]),int(df.iloc[x][3]),int(df.iloc[x][4]),trade_count)).start()
        x+=1
        time.sleep(2) 

 